package com.codeduck.kafka.handler;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;

/**
 * @auther Mahone Yan
 * @date 2023/5/7
 */
public abstract class IMessageHandler {

    /**
     * 处理消费
     */
    public void consume(ConsumerRecord<Object, Object> record) {};

    /**
     * 批量处理消息
     */
    public void batchConsume(ConsumerRecords<Object, Object> records){};

}
